package com.wj.dubbo.service.task;

import com.wj.console.rabbit.message.CrawlerSocialFundMessage;

public interface ITaskService {

	/**
	 * 暂停任务
	 */
	void pauseTask(CrawlerSocialFundMessage message);
	/**
	 * 启动任务
	 */
	void startTask();
	
	/**
	 * 提交任务
	 */
	<T extends CrawlerTask> void submitTask(T task);
	
	/**
	 * 运行任务
	 * @param message
	 */
	void runTask(CrawlerSocialFundMessage message) throws Exception;
	/**
	 * 判断服务是否暂停
	 * @return
	 */
	boolean isPaused();
	
	/**
	 * 暂停服务
	 */
	void pause(int minute);
}
